package main.scala

import org.apache.spark.sql.SparkSessionExtensions

class MySparkSessionExtension extends (SparkSessionExtensions => Unit){
  override def apply(v1: SparkSessionExtensions): Unit = {
    v1.injectOptimizerRule { session =>
      new MyPushDown(session)
    }
  }
}
